// server.js
const WebSocket = require("ws");

// 创建 WebSocket 服务器，监听 8080 端口
const wss = new WebSocket.Server({ port: 8080 });

console.log("WebSocket 服务器已启动，监听 ws://localhost:8080");

// 监听连接事件
wss.on("connection", (ws) => {
  console.log("新的客户端连接");

  // 监听客户端发来的消息
  ws.on("message", (message) => {
    console.log(`收到消息: ${message}`);

    // 广播消息给所有客户端
    wss.clients.forEach((client) => {
      if (client.readyState === WebSocket.OPEN) {
        client.send(`服务器收到消息: ${message}`);
      }
    });
  });

  // 监听连接关闭事件
  ws.on("close", () => {
    console.log("客户端断开连接");
  });

  // 发送欢迎消息
  ws.send("欢迎连接到 WebSocket 服务器!");
});
